from celery import Celery

broker = 'redis://127.0.0.1:6379/1'
backend = 'redis://127.0.0.1:6379/2'
# 任务分到不同的py文件中了
app = Celery('demo', broker=broker, backend=backend,
             include=['celery_task.crawl_task', 'celery_task.order_task', 'celery_task.user_task'])


# celery -A celery_task worker -l info -P eventlet